<?php
	/**
	 *连接数据库
	 */
	function connect()
	{
		//使用，主机名，用户名，密码登录到数据库中
		$link = @mysqli_connect(HOST, USER, PWD);
		//判断是否连接成功
		if (!$link) {
			$info['error'] = false;
			$info['mess'] = 'ERROR'.'('.mysqli_connect_errno().'):'.mysqli_connect_error();
			return $info;
		}
		//选择数据库,并判断错误
		if (!mysqli_select_db($link, DB)){
			$info['error'] = false;
			$info['mess'] = 'ERROR'.'('.mysqli_errno($link).'):'.mysqli_error($link);
			return $info;
		}
		//设置字符集，并判断错误
		if (!mysqli_set_charset($link, CHAR)) {
			$info['error'] = false;
			$info['mess'] = 'ERROR'.'('.mysqli_errno($link).'):'.mysqli_error($link);
			return $info;
		}
		
		//连接成功，返回数据	
		$info['error'] = true;
		$info['mess'] = $link;
		return $info;
	}

	/**
	 *带数据的结果集的操作
	 *@param object $link 数据库连接成功返回的对象
	 *@param string $sql 执行的sql语句
	 */
	function query($link, $sql) {
		//发生sql语句
		$result = mysqli_query($link, $sql);

		//进行判断
		if (!$result) {
			$info['error'] = false;
			$info['mess'] = 'ERROR'.'('.mysqli_errno($link).'):'.mysqli_error($link);
			return $info;
		}

		//进行循环，取出所有的数据
		while ($row = mysqli_fetch_assoc($result)) {
			$rows[] = $row;
		}
		return @$rows;
	}

	/**
	 *没有返回数据的结果集操作
	 *@param object $link 数据库连接成功返回的对象
	 *@param string $sql 执行的sql语句
	 */
	function excute($link, $sql)
	{
		//发生sql语句
		$result = mysqli_query($link, $sql);

		//进行判断
		if (!$result) {
			$info['error'] = false;
			$info['mess'] = 'ERROR'.'('.mysqli_errno($link).'):'.mysqli_error($link);
			return $info;
		}
		//sql执行成功的返回值
		$info['error'] = true;
		$info['mess'] =  mysqli_insert_id($link)?mysqli_insert_id($link):mysqli_affected_rows($link);
		return $info;
	}
?>